f0370f4b01a4d3a03532c2f82130574f2894a358,protocol/src/main/java/org/jboss/as/protocol/ProtocolChannelClient.java,ProtocolChannelClient,connectSync,#CallbackHandler#Map#,131

Before Change



    public Connection connectSync(CallbackHandler handler, Map<String, String> saslOptions) throws IOException {
        final IoFuture<Connection> future = connect(handler, saslOptions);
        final IoFuture.Status status = future.await(configuration.getConnectionTimeout(), TimeUnit.MILLISECONDS);
        if(status == IoFuture.Status.DONE) {
            return future.get();
        }

After Change


    public Connection connectSync(CallbackHandler handler, Map<String, String> saslOptions) throws IOException {
        WrapperCallbackHandler wrapperHandler = new WrapperCallbackHandler(handler);
        final IoFuture<Connection> future = connect(wrapperHandler, saslOptions);
        long timeoutMillis = configuration.getConnectionTimeout();
        IoFuture.Status status = future.await(timeoutMillis, TimeUnit.MILLISECONDS);
        while (status == IoFuture.Status.WAITING) {
            if (wrapperHandler.isInCall()) {
                // If there is currently an interaction with the user just wait again.
                status = future.await(timeoutMillis, TimeUnit.MILLISECONDS);